package com.tql.simple;

import com.rabbitmq.client.*;
import com.tql.util.ConnectionUtil;


public class Producer {
    private final static String QUEUE_NAME="first_queue";
    public static void main(String[] args) throws Exception{
        Connection connection=null;
        try{
            connection=ConnectionUtil.getConnection();
            Channel channel = connection.createChannel();

         /*   * @param1 队列名称
            * @param2 是否持久化
            * @param3 是否支持排他性
            * @param4 最后一个消费者消费完消息是否自动删除，
            * @parma5 传入参数
            * */
            //声明队列
            channel.queueDeclare(QUEUE_NAME,false,false,false,null);
            String message="hello world";
            //发送消息
            channel.basicPublish("",QUEUE_NAME,null,message.getBytes());
            System.out.println("发送消息"+message+"成功！");

        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if (connection!=null&&connection.isOpen()){
                connection.close();
            }
        }
    }


}
